from db import RedisOperator
from settings.settinglod import Setting
import json
import multiprocessing

from conduit.conunt import InitConduit, RedisConduit


class Manage(object):
    "中央管理器"
    def __init__(self, setting: Setting):
        self.setting_conf = setting
        self.redis = RedisOperator(setting)

        # 初始化管道
        subclass = InitConduit.__subclasses__()

    def run(self):
        "开始任务"
        original = self.redis.get()
        data = json.loads(original)  # 解析后数据


